/*
package com.ytxt.taskdemo.asyncevent;

import com.google.common.eventbus.EventBus;
import com.google.common.eventbus.SubscriberExceptionHandler;

import java.util.concurrent.Executor;

public class AsyncEventBus extends EventBus {
    */
/**
     * 创建AsyncEventBus对象
     *
     * @param identifier EventBus标识
     * @param executor 消息在哪里执行，EventBus里面默认的是MoreExecutors.directExecutor()
     *//*

    public AsyncEventBus(String identifier, Executor executor) {
        super(identifier, executor, Dispatcher.legacyAsync(), LoggingHandler.INSTANCE);
    }

    */
/**
     * 创建AsyncEventBus对象
     *
     * @param executor 消息在哪里执行，EventBus里面默认的是MoreExecutors.directExecutor()
     * @param subscriberExceptionHandler 异常处理
     * @since 16.0
     *//*

    public AsyncEventBus(Executor executor, SubscriberExceptionHandler subscriberExceptionHandler) {
        super("default", executor, Dispatcher.legacyAsync(), subscriberExceptionHandler);
    }

    */
/**
     * 创建AsyncEventBus对象
     *
     * @param executor 消息在哪里执行，EventBus里面默认的是MoreExecutors.directExecutor()
     *//*

    public AsyncEventBus(Executor executor) {
        super("default", executor, Dispatcher.legacyAsync(), LoggingHandler.INSTANCE);
    }
}
*/
